5b781e04cf13b5f5e54fe9f48c9e7aff729782ad,modules/siddhi-extensions/input-mappers/map-input-mapper/src/test/java/org/wso2/siddhi/extension/input/mapper/map/MapInputMapperTestCase.java,MapInputMapperTestCase,subscriptionTest12,#,40
Before Change
public void subscriptionTest12() throws InterruptedException {
log.info("Subscription Test 12: Test an in memory transport with hashmap");
Subscription subscription = Subscription.Subscribe(Transport.transport("inMemory"));
subscription.map(Mapping.format("map"));
subscription.insertInto("FooStream");
After Change
public void subscriptionTest12() throws InterruptedException {
log.info("Subscription Test 12: Test an in memory transport with default hashmap mapping");
Subscription subscription = Subscription.Subscribe(Transport.transport("inMemory").option("topic","stock"));
subscription.map(Mapping.format("map"));
subscription.insertInto("FooStream");